package com.temperate;

import org.apache.hadoop.io.DoubleWritable;
import org.apache.hadoop.mapreduce.Partitioner;

/**
 * @author:wesley
 */
public class TempPartition extends Partitioner<TempKey,DoubleWritable> {

    public int getPartition(TempKey tempKey, DoubleWritable doubleWritable, int i) {
        return (tempKey.getYear()-1949)%i;
    }
}
